#ifndef STREAM_PULLER_H
#define STREAM_PULLER_H

#include "Module/Module.h"
using namespace MxBase;

extern "C" {
    #include "libavformat/avformat.h"
}


class StreamPuller : public Module {
public:
    StreamPuller() = default;
    virtual ~StreamPuller() = default;

    virtual APP_ERROR Init();
    virtual APP_ERROR Process(const std::shared_ptr<void> &input);
    virtual APP_ERROR DeInit();
    virtual std::string GetModuleName();
private:
    AVFormatContext *pFormatCtx_;

};

#endif